import pydatadiskvec
import time
import random
import threading
print("debug")
input()
#a=time.time()
b=pydatadiskvec.pydatadiskvec(0.2,3, 3, 0.5, 0.01,0.1, "test", True, 0.5, "maptest", "C:/Users/linxingjun/pynetdatavec/disktestcache")
#print(time.time()-a)
d=pydatadiskvec.pydatadiskvec(0.2,16, 16, 0.5, 0.01,0.1, "testq", True, 0.5, "maptesqt", "C:/Users/linxingjun/pynetdatavec/disktestcachwe")

def a():
    while True:
        b.dataadd(random.random())
        d.dataadd(random.random())
if __name__ == "__main__":
    for i in range(300):
        c=threading.Thread(target=a)
        c.start()
    while True:
        print(b.dataget())
        print(d.dataget())
